//package com.yuyou.train.stream.sendto;
//
//import org.slf4j.Logger;
//import org.slf4j.LoggerFactory;
//import org.springframework.cloud.stream.annotation.EnableBinding;
//import org.springframework.cloud.stream.annotation.StreamListener;
//import org.springframework.cloud.stream.messaging.Processor;
//import org.springframework.messaging.handler.annotation.SendTo;
//
//@EnableBinding(value = { Processor.class })
//public class Appl {
//
//	private final Logger logger = LoggerFactory.getLogger(this.getClass());
//
//	@StreamListener(Processor.INPUT)
//	@SendTo(Processor.OUTPUT)
//	public Object receiveFrominput(Object payload) {
//		logger.info("Received: " + payload);
//		return "From Input Channel Return - " + payload;
//	}
//
//}
